package com.ruleengine.worker.runner.rule.other;

import com.ruleengine.worker.model.Rule;
import com.ruleengine.worker.runner.rule.PubSubRuleRunner;

import io.vertx.core.Vertx;
import lombok.extern.slf4j.Slf4j;

/**
 * For test
 *
 * @author lianghanwei on 2024/2/18
 */
@Slf4j
public class SimpleLogRuleRunner extends PubSubRuleRunner<String, String> {
    public SimpleLogRuleRunner(Vertx vertx, String name, Rule rule) {
        super(vertx, name, rule);
    }

    @Override
    public String process(String item) {
        log.info("{} processing item={}", name, item);
        return item;
    }
}
